package com.leaf.lowcode.generator;

import com.leaf.lowcode.entity.VisitBean;
import org.junit.Test;


import java.lang.reflect.Field;
import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Statement;

public class BeanToTableUtils {



    @Test
    public void test() {
        generateSql(VisitBean.class);
    }

    public static void generateSql(Class obj){
        System.out.println("程序开始运行！");

        StringBuilder table = new StringBuilder();
        String[] list = obj.getName().split("\\.");
        table.append(list[0]).append("_").append(list[2].substring(4)).append("_").append(list[3].toLowerCase());
        String tableName = table.toString();

        Connection connection = ConnectMySql.connect();
        Statement statement = null;

        String className = obj.getName();
        System.out.println("类名为：" + className);

        Field[] fields = obj.getDeclaredFields();
        //字段类型
        String param = null;
        //字段名
        String cameCaseColumn = null;
        StringBuilder sql = new StringBuilder();
        if(tableName==null||tableName.equals("")){
            // 未传表明默认用类名
            tableName = obj.getName().substring(obj.getName().lastIndexOf(".")+1);
        }
        /**
         * 以下部分生成建表Sql
         */
//        sql.append("DROP TABLE IF EXISTS ").append("`").append(tableName).append("`").append(";\r\n");
        sql.append("CREATE TABLE ").append("`").append(tableName).append("`").append(" ( \r\n");
        sql.append("`custid` varchar(255) DEFAULT NULL");
        sql.append(",\n");
        //判断属性rptDate是否存在
        Boolean flag1 = false;
        //判断以Date结尾的属性，并在相应的表中设置其类型为Date
        Boolean flag2 = false;
        for(Field f : fields){
            cameCaseColumn = f.getName();
            //判断属性rptDate是否存在
            if (cameCaseColumn.equalsIgnoreCase("rptDate")) {
                flag1 = true;
            }
            //判断以Date结尾的属性，并在相应的表中设置其类型为Date
            if (cameCaseColumn.substring(cameCaseColumn.length()-4).equalsIgnoreCase("Date")) {
                flag2 = true;
            }
            param = f.getType().getTypeName();
            //只有String类型和date类型的属性才创建表字段
            if (flag2) {
                sql.append("`").append(cameCaseColumn).append("`").append(" ");
                sql.append("date DEFAULT NULL");
                sql.append(",\n");
            } else if (param.equals("java.lang.String")) {
                sql.append("`").append(cameCaseColumn).append("`").append(" ");
                sql.append("varchar(255) DEFAULT NULL");
                sql.append(",\n");
            }
//            if(param.equals("java.lang.String")){
//            	sql.append("`").append(cameCaseColumn).append("`").append(" ");
//                sql.append("varchar(255) DEFAULT NULL");
//                sql.append(",\n");
//            }else if(param.equals("java.sql.Date")){
//                // 根据需要自行修改
//            	sql.append("`").append(cameCaseColumn).append("`").append(" ");
//                sql.append("date DEFAULT NULL");
//                sql.append(",\n");
//            }
        }
        if (className.contains("Record")) {
            if (!flag1) {
                sql.append("`").append("rptDate").append("`").append(" ").append("date DEFAULT NULL").append(",\n");
            }
            sql.append("`").append("c1").append("`").append(" ").append("varchar(255) DEFAULT NULL").append(",\n");
            sql.append("`").append("c2").append("`").append(" ").append("varchar(255) DEFAULT NULL").append(",\n");
            sql.append("`").append("c3").append("`").append(" ").append("varchar(255) DEFAULT NULL").append(",\n");
            sql.append("`").append("c4").append("`").append(" ").append("varchar(255) DEFAULT NULL").append(",\n");
            sql.append("`").append("c5").append("`").append(" ").append("varchar(255) DEFAULT NULL").append(",\n");
        }
        else {
            if (!flag1)
                sql.append("`").append("rptDate").append("`").append(" ").append("date DEFAULT NULL").append(",\n");
        }
        sql.delete(sql.lastIndexOf(","), sql.length()).append("\n) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;\r\n");
        System.out.println(sql);

        try {
            statement = connection.createStatement();
            statement.executeUpdate(sql.toString());
            System.out.println("创建表成功！");
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

}
